package test;

import com.alibaba.fastjson.JSONObject;
import com.mico.micochange.server.MicoThread;
import com.mico.xchange.Exchange;
import com.mico.xchange.ExchangeFactory;
import com.mico.xchange.okcoin.OkCoinExchange;
import com.mico.xchange.okcoin.dto.marketdata.OkCoinExchangeRate;
import com.mico.xchange.okcoin.service.OkCoinMarketDataServiceRaw;
import org.apache.mina.core.session.IoSession;

import java.math.BigDecimal;
import java.util.HashMap;
import java.util.Map;

/**
 * Created by chenst on 2018/5/6.
 */
public class GetExchangeRateTestThread extends Thread{
    //创建连接对象，作用返回处理结果
    private IoSession session;
    //输入参数
    private String message;

    public GetExchangeRateTestThread(IoSession session,String message){
        this.session = session;
        this.message = message;
    }

    @Override
    public void run(){
        try {
            Thread.sleep(50000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        //返回数据
        session.write("fsdf$$$$$$");
    }
}
